package com.zytech.zspider.eventbus.rabbitmq;

import com.rabbitmq.client.ConnectionFactory;
import com.zytech.zspider.eventbus.support.AbstractEventBus;

/**
 * @author siuming
 */
public class RabbitMQEventBus extends AbstractEventBus {

    /**
     * @param eventOperations
     * @param listenerContainer
     */
    public RabbitMQEventBus(ConnectionFactory connectionFactory) {
        super(
                new RabbitMQOperations(connectionFactory),
                new RabbitMQEventListenerContainer(connectionFactory)
        );
    }
}
